package com.stlm2.core.redis.queue;

import com.stlm2.core.redis.RedisClient;
import redis.clients.jedis.Jedis;

/**
 * 入队操作
 */
public class Pusher {

    /**
     * 入队
     * @param queue
     * @param message
     */
    public static void push(String queue, String message){
        Jedis jedis = RedisClient.getResource();
        jedis.lpush(queue, message);
        RedisClient.returnResource(jedis);
    }
}
